package com.yy.job.core.dataprocess;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.yy.job.core.domain.JobDomain;
import com.yy.job.core.run.worker.ModuleWorker;

/**
 * 高优先级任务处理器，提交的任务在本机立即执行
 * 
 * @author eleven.li
 *
 */
public class PriorityJobDataProcess extends SingleJobDataProcess {
	
	private Logger log = LoggerFactory.getLogger(PriorityJobDataProcess.class);
	
	public PriorityJobDataProcess(ModuleWorker moduleWorker) {
		super(moduleWorker);
	}

	@Override
	public void execute(JobDomain jobDomain) {
		log.info("start PriorityJobDataProcess, moduleWorker name={}", this.moduleWorker.getModuleWorkerName());
		this.moduleWorker.assignJobToWoker(jobDomain);
	}

}
